package org.poem;

import com.alibaba.otter.canal.protocol.CanalEntry;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;

import java.util.List;

/**
 * @author poem
 */
@Data
@NoArgsConstructor
@AllArgsConstructor
public class CanalClientHeadEntityVO {

    /**
     * 更新的方式
     */
    private CanalEntry.EventType eventType;
    /**
     * 日志文件
     */
    private String binlog;

    /**
     * 日志文件的编码
     */
    private Long logfileOffset;

    /**
     * 影响的mysql的schema
     */
    private String schemaName;

    /**
     * 被操作的数据表
     */
    private String tableName;

    /**
     * 执行的 sql
     */
    private List<String> sql;
    /**
     * 所有这次所更改的数据
     */
    List<CanalClientEntryVO>  entries;

    /**
     * 所有这次所更改的数据
     */
    List<CanalClientEntryVO>  beforeEntries;
}
